package com.qst.order.service;


import com.qst.order.domain.DTO.QueueMessage;
import com.qst.order.service.Impl.RabbitMQMonitorServiceImpl;

import java.util.List;

public interface RabbitMQMonitorService  {
     void collectQueueMessageCount();

     List<String> getQueueTrendTimestamps(String queueName, int timeRange);
     List<Integer> getQueueTrendMessageCounts(String queueName, int timeRange);

     List<QueueMessage> getQueueMessages(String queueName, int pageSize);

     void clearQueue(String queueName);
     List<RabbitMQMonitorServiceImpl.QueueBasicInfo> getQueueBasicInfos();
}
